from elasticsearch import AsyncElasticsearch
from common.pkg.es_util import SPUESClient


def init_es_client(es_config: dict):
    return AsyncElasticsearch(**es_config)


def init_spu_es_client(es_client):
    return SPUESClient(es_client)